#!/usr/bin/env python
import pika

cred = pika.PlainCredentials('cve_work', 'cve_work')
conn = pika.BlockingConnection(pika.ConnectionParameters(host='118.178.239.213', port=21121, credentials=cred))
channel = conn.channel()

channel.queue_declare(queue='hello')

channel.basic_publish(exchange='', routing_key='hello', body=b'Hello World!')
print(" [x] Sent 'Hello World!'")
conn.close()
